package com.lee.study.thrift.netty;

import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;

public class ThriftNettyHandlerInitializer extends ChannelInitializer<SocketChannel> {

    @Override
    protected void initChannel(SocketChannel ch) throws Exception {
        //添加解码 和 编码器
        ChannelPipeline pipeline = ch.pipeline();
        pipeline.addLast(new ThriftResponse());
//        pipeline.addLast(new ThriftDecoder());

        //添加调用器
    }
}
